package com.lzyx.hello

import reactor.core.publisher.Flux
import java.util.function.Consumer

class ReactorTest {

}

fun main(){
    Flux.just("hello", "dog", "god", "bless")
        .filter { it.length > 3 }
        .map { it + "_S" }
        .subscribe{ println(it) };
}